package net.ziyoushu.demo1.holder;

import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
import org.apache.rocketmq.client.consumer.rebalance.AllocateMessageQueueAveragely;
import org.apache.rocketmq.remoting.RPCHook;

public class AsynMessageConsumerHoler extends DefaultMQPushConsumer {

    public AsynMessageConsumerHoler(String producerGroup) {
        super(producerGroup, (RPCHook)null, new AllocateMessageQueueAveragely());
    }
}
